import pymysql

#1.建立数据库连接
connect = pymysql.connect(
    # MySQL数据库的IP地址，默认127.0.0.1（代表本地）
    host='127.0.0.1',
    # MySQL数据库的用户名
    user='root',
    # MySQL数据库的密码
    password='123456',
    # MySQL数据库服务的端口号；默认为3306
    port=3306,
    # 数据库名称
    db='spider',
    # 字符编码
    charset='utf8'
)
#2.使用cursor()方法获取操作游标
cursor = connect.cursor()
#3.创建products表
#如果products表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS products")
#创建数据表SQL语句
productsSql = """CREATE TABLE products (
         id BIGINT(20)  NOT NULL AUTO_INCREMENT,
         top_class VARCHAR(20),
         sec_class VARCHAR(20),
         product_name VARCHAR(50),
         low_price FLOAT,
         avg_price FLOAT,
         high_price FLOAT,
         specs VARCHAR(20),
         origin VARCHAR(20),
		   unit VARCHAR(5),
         update_time DATETIME,
         PRIMARY KEY (`id`))
         """
#执行创建表
cursor.execute(productsSql)

#4.关闭数据库连接
connect.close()
